package channelScheduler

import "gitee.com/fierce_wolf/go-fox-edge-common/edgeEntity"

var (
	respondScheduler  *channelRespondScheduler
	reportToScheduler *channelReportToScheduler
	manageScheduler   *channelManageScheduler
)

func init() {
	respondScheduler = &channelRespondScheduler{}
	reportToScheduler = &channelReportToScheduler{}
	manageScheduler = &channelManageScheduler{}
	manageScheduler.channelEntityMap = make(map[string]*edgeEntity.ChannelEntity)
}

// Scheduler 线程函数
func Scheduler() {
	respondScheduler.Scheduler()
	reportToScheduler.Scheduler()
	manageScheduler.Scheduler()
}
